#include "../../client/rpc_client.hpp"

int main() 
{
    // 1. 实例化客户端对象
    auto client = std::make_shared<rcrpc::client::TopicClient>("127.0.0.1",7070);
    // 2. 创建主题
    bool ret = client->create("hello");
    if(ret == false) {
        ELOG("创建主题失败");
    }

    // 3. 向主题发布消息
    for (int i = 0; i < 10; i++) {
        client->publish("hello","Hello world" + std::to_string(i));
    }
    client->shutdown();
    return 0;
}